package com.x.rocketmq.content;

import com.x.rocketmq.init.RocketMQProducerInit;
import java.util.concurrent.ConcurrentHashMap;

public class RocketMQContents
{
	
	/**
	 * 
	 */
//	public static Map<String, RocketMQConcurrentlyConsumerInit> APPCONSUMERINITMAP = new ConcurrentHashMap<String, RocketMQConcurrentlyConsumerInit>();
//
//	/**
//	 * 基于服务治理动态补偿
//	 */
//	public static Map<String, MessageHandler> SERVICEAUTOCOMPENSATEMAP = new HashMap<String, MessageHandler>();
//
//	/**
//	 * 当前应用所配置使用的消费者组
//	 */
//	public static Map<String, ConsumerCommand> APP_CONSUMER_MAP = new ConcurrentHashMap<String, ConsumerCommand>();
//
//	/**
//	 * 集群字符串匹配
//	 * 生产者用于匹配集群是否发生变更
//	 */
//	public static Map<Long, MessageBrokerCluster> CLUSTER_MAP_String = new HashMap<Long, MessageBrokerCluster>();
//
//	/**
//	 * 当前租户所关联的rmq集群
//	 */
//	public static ConcurrentHashMap<Long, ClusterCommand> CLUSTER_MAP = new ConcurrentHashMap<Long, ClusterCommand>();
//
//	/**
//	 * 消费者根据 clusterId获取连接的rmq集群地址
//	 */
//	public static ConcurrentHashMap<Long, String> CLUSTER_ADDR = new ConcurrentHashMap<Long, String>();

	/**
	 * 消息队列在选择发送消息数据时，根据clusterId 决定发送至哪个rmq集群
	 */
	public static ConcurrentHashMap<Long, RocketMQProducerInit> ROCKETMQ_PRODUCER = new ConcurrentHashMap<Long, RocketMQProducerInit>();

//	/**
//	 * 本地消息队列信息列表
//	 * 使用本地线程来保护当topic连接的集群地址发生变更时，出现找不到指定的rmq集群的情况
//	 */
//	public static ConcurrentHashMap<String, MessageDestination> LOCAL_TOPIC = new ConcurrentHashMap<String, MessageDestination>();
	
}